package com.tianxiabuyi.weixin.qy.message;


import com.tianxiabuyi.utils.JSONUtil;
import com.tianxiabuyi.weixin.common.WxClient;
import com.tianxiabuyi.weixin.qy.QyWxClientFactory;
import com.tianxiabuyi.weixin.qy.message.json.JsonMessage;

/**
 * 消息发送
 */
public class Messages {

    private WxClient wxClient;

    /**
     * 初始化wxclient
     * @param corpId
     * @param corpSecret
     * @return
     */
    public static Messages with(String corpId, String corpSecret) {
        Messages messages = new Messages();
        messages.setWxClient(QyWxClientFactory.getInstance().with(corpId, corpSecret));
        return messages;
    }

    /**
     * 设置wxclient，如果已使用with初始化，则不用调用该方法
     * @param wxClient
     */
    public void setWxClient(WxClient wxClient) {
        this.wxClient = wxClient;
    }

    /**
     * 发送消息
     * @param message
     */
    public String send(JsonMessage message) {
        String url = "https://qyapi.weixin.qq.com/cgi-bin/message/send";
        String json = JSONUtil.toJson(message);
       return  wxClient.post(url, json);
    }
}
